package kuaizu.kuaizumqserver.bius;

import kuaizu.common.mqconst.MQConstant;
import kuaizu.kuaizumqserver.config.MQConfig;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class ProjectMassageMq {
    @RabbitListener(queues = MQConstant.PROJECT_SEND_QUEUE)
    public void sendProjectMessage(String message) {
        System.out.println("发送消息到队列：" + message);
    }

    @RabbitListener(queues = MQConstant.PROJECT_SEND_QUEUE_DLX)
    public void sendProjectMessageDlx(String message) {
        System.out.println("发送消息到死信队列：" + message);
    }

    //发送订阅消息


}
